package com.example.util;

import org.I0Itec.zkclient.ZkClient;

/**
 * @Description: zk 连接工具类
 * @Author: mingtian
 * @CreateDate: 2020/12/5 11:45
 * @Version: 1.0
 */
public class ZkUtils {
    /**
     * zk 连接
     */
    private static ZkClient zkClient = null;

    /**
     * 返回 zk 连接
     *
     * @return
     */
    public static ZkClient getZkClient() {
        return zkClient;
    }

    /**
     * 创建 zk 连接
     *
     * @return
     */
    public static ZkClient createZkClient() {
        if (zkClient == null) {
            zkClient = new ZkClient("127.0.0.1:2181", 5000);
        }
        return zkClient;
    }

    /**
     * 关闭 zk 连接
     */
    public static void close() {
        if (zkClient != null) {
            zkClient.close();
            zkClient = null;
        }
    }
}